package com.ds.infra.mq.core.protocol;

import lombok.Getter;

/**
 * 作用：定义消息类型枚举类，用于标识不同类型的消息。
 *
 * @author WeiShaoying
 */
@Getter
public enum MessageType {

    /**
     * 生产者请求消息
     */
    PRODUCE_REQUEST(0x01),

    /**
     * 生产者响应消息
     */
    PRODUCE_RESPONSE(0x02),

    /**
     * 消费者请求消息
     */
    CONSUME_REQUEST(0x03),

    /**
     * 消费者响应消息
     */
    CONSUME_RESPONSE(0x04),

    /**
     * 心跳消息
     */
    HEARTBEAT(0x05);

    private final int code;

    MessageType(int code) {
        this.code = code;
    }

    public static MessageType fromCode(int code) {
        for (MessageType type : values()) {
            if (type.code == code) {
                return type;
            }
        }
        throw new IllegalArgumentException("Unknown message type code: " + code);
    }
}
